package test.sunyu.tools.netty;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;

import java.net.InetAddress;

public class HelloServerHandler extends SimpleChannelInboundHandler<String> {

    @Override
    protected void channelRead0(ChannelHandlerContext ctx,
                                String msg) throws Exception {
        // 收到消息直接打印输出
        System.out.println("收到客户端 ：" + ctx.channel().remoteAddress() + " 的消息 : " + msg);

        // 返回客户端消息 - 我已经接收到了你的消息
        ctx.writeAndFlush("服务端已收到消息 !\r\n");
    }

    @Override
    public void channelActive(ChannelHandlerContext ctx) throws Exception {

        System.out.println("客户端 : " + ctx.channel().remoteAddress() + " 已连接 !");

        ctx.writeAndFlush("欢迎 " + InetAddress.getLocalHost().getHostName() + " 连接服务 !\r\n");

        super.channelActive(ctx);
    }
}